import sqlite3
con = sqlite3.connect("webkafka.db")
cur = con.cursor()


"""
init_db
初始化各种表
    1、包括topic表
    id   topic_name   status 
"""


def init_db(cur):
    init_topic_table = "CREATE TABLE IF NOT EXISTS TOPIC(id TEXT PRIMARY KEY NOT NULL, topic_name TEXT, status INT)"
    cur.execute(init_topic_table)

init_db(cur)




